//package com.per.mybootall.kafka;
//
//import org.springframework.kafka.core.KafkaTemplate;
//import org.springframework.kafka.support.SendResult;
//import org.springframework.scheduling.annotation.EnableScheduling;
//import org.springframework.scheduling.annotation.Scheduled;
//import org.springframework.stereotype.Component;
//import org.springframework.util.concurrent.ListenableFuture;
//import org.springframework.util.concurrent.ListenableFutureCallback;
//
//import javax.annotation.Resource;
//import java.text.ParseException;
//import java.text.SimpleDateFormat;
//import java.util.Date;
//import java.util.regex.Matcher;
//import java.util.regex.Pattern;
//
///**
// * Created with IntelliJ IDEA.
// *
// * @author: yyy
// * Date: 2021/10/19
// * Time: 16:57
// * Description:
// */
//@Component
//@EnableScheduling
//public class kafkaProduct {
//
//    @Resource
//    private KafkaTemplate<String, String> kafkaTemplate;
//    @Scheduled(cron = "0/30 * * * * ?")
//    public void send() {
//        System.out.println("kafka定时器开始执行----------------------------------》》》》》》》》》》》》》》》》》");
//        SimpleDateFormat sif=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
//        for(int i=0;i<10;i++){
//            String msg="生产者向kafka发送的数据"+sif.format(new Date())+"-" +i;
//            ListenableFuture<SendResult<String, String>> future = kafkaTemplate.send("myKafkaTopic", msg);
//            future.addCallback(new ListenableFutureCallback<SendResult<String, String>>() {
//                @Override
//                public void onFailure(Throwable throwable) {
//                    System.out.println("发送失败");
//                }
//
//                @Override
//                public void onSuccess(SendResult<String, String> stringStringSendResult) {
//                    System.out.println("发送完成");
//                }
//            });
//        }
//
//
//
//    }
//
//    public static void main(String[] args) throws ParseException {
//        SimpleDateFormat sdf = new SimpleDateFormat("MM-dd");
//        String time="2021-10-26 10:05:51";
//
//        System.out.println(time.substring(5,10));
//    }
//
//
//    public static boolean checkEmailFormat(String email){
//        if (null==email || "".equals(email)){
//            return false;
//        }
//        String regEx1 = "^([a-z0-9A-Z]+[-|\\.]?)+[a-z0-9A-Z]@([a-z0-9A-Z]+(-[a-z0-9A-Z]+)?\\.)+[a-zA-Z]{2,}$";
//        Pattern p = Pattern.compile(regEx1);
//        Matcher m = p.matcher(email);
//        if(m.matches()){
//            return true;
//        }else{
//            return false;
//        }
//    }
//
//}
